package com.feishi.core.util.queue;

/**
 * Created by caixq on 4/25 025.
 */
public interface Customer<T> {
    /**
     * T：消息内容
     * sequence:执行序号
     * endOfBatch:是否本队列执行结束
     * */
    void execute(T t, long sequence, boolean endOfBatch) throws InterruptedException, Exception;
}
